package com.test.myrxjava.core;

public interface ObservableOnSubscribe<T> {//被观察者和事件发射器的关系接口？？？？

    void subscribe(Emitter<T> emitter);//观察者被订阅

}
